#include <unistd.h>
#include <iostream>
#include <cstdio>
#include <cassert>
#include <cstring>
#include <cstdlib>
#include <sys/types.h>
#include <sys/wait.h>
using namespace std;
// 父进程读取，子进程写入
int main()
{

    // 第一步父进程创建管道
    // 输出型参数  
    // fd[0] refers to the read end of the pipe 读端
    // fd[1] refers to the write end of the pipe 写端
    int fds[2];
    int n = pipe(fds);// 成功返回0
    assert(n == 0);
    // 第二步父进程创建子进程
    int cnt = 0;
    const char* msg = "我是子进程，我的pid是 ";
    pid_t id = fork();// 子进程返回0，父进程返回子进程pid
    assert(id >= 0);
    if (id == 0)
    {
        close(fds[0]);// 子进程关闭读端
        // 子进程通信
        while (true)
        {
            char buffer[1024];// 这个缓冲区只有子进程看得到
            snprintf(buffer, sizeof(buffer), "子进程向父进程第%d次发送：%s%d，ppid是%d\n", ++cnt, msg, getpid(), getppid());
            write(fds[1], buffer, strlen(buffer));// 子进程将buffer中的数据写入
            sleep(1);
            if (cnt >= 5) break;
        }
        close(fds[1]);
        exit(0);
    }
    close(fds[1]); // 父进程关闭写端
    while (true)
    {
        char buffer[1024];// 只有父进程看得到
        // 如果管道中没有数据，读端读，默认会阻塞进程
        ssize_t n = read(fds[0], buffer, sizeof(buffer) - 1);
        if (n > 0)
        {
            buffer[n] = '\0';
            cout << "父进程的pid是 " << getpid() << " 读到的信息：" << buffer << endl;
        }
        else if (n == 0)
        {
            cout << "读完了" << endl;
            break;
        }
    }
    pid_t ret = waitpid(id, nullptr, 0);// 阻塞等待，成功返回子进程pid
    assert(ret == id);
    close(fds[0]);// 父进程读完关闭读端
    return 0;
}